package com.cold.demo.rabbitmq.demo2.$1queue;

import com.cold.demo.rabbitmq.utils.ConnectionUtils;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

import java.io.IOException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;

/**
 * 直接发送到某一个队列中去
 *
 * @author: zyc
 */
public class Publisher {

    public static void main(String[] args) throws Exception {
        Connection connection = ConnectionUtils.getConnection();
        Channel channel = connection.createChannel();
        // 声明队列
        // 1、队列名称
        // 2、是否持久化消息
        // 3、是否独占队列
        // 4、是否自动删除队列
        // 5、参数–队列的其他属性（构造参数）
//        channel.queueDeclare("test1", true, false, false, null);

        // 发送消息
        // 1、将消息发布到指定的交换机
        // 2、routingKey – 路由
        // 3、消息的其他属性
        // 4、正文
        while (true) {
            try {
                channel.basicPublish("", "business-queue22-test", null, (System.currentTimeMillis() + "这里是消息数据").getBytes());
                TimeUnit.MILLISECONDS.sleep(100);
            }catch (Exception e){
                e.printStackTrace();
                break;
            }
        }
        channel.close();
        connection.close();

    }
}
